背景 最近發現Confluent公司在官網上發布了Kafka Streams教程，共有10節課，每節課給出了Kafka Streams的一個功能介紹。這個系列教程對於我們了解Kafka Strea ...

本文從以下四個方面手把手教你寫Kafka Streams程序: 一. 設置Maven項目 二. 編寫第一個Streams應用程序：Pipe 三. 編寫第二個Streams應用程序：Line Sp ...

1. 背景 上一篇介紹了如何利用Kafka Streams實時統計某年最賣座和最不賣座的電影票房。主要的方法是通過Streams提供的aggregate方法實現了max/min算子。今天我為大家帶來 ...

1. 背景 上一篇介紹了Kafka Streams的時間窗口以及Tumbling Window的實例。這一篇我們利用Kafka Streams中的KTable概念來實時計算一組電影的平均分數。 2 ...

1. 背景 上一篇介紹了如何利用Kafka Streams找出並過濾掉實時流中那些重復的消息。本篇將介紹如何對消息中特定數據進行求和匯總。 2. 功能演示說明 假設我們要執行匯總求和的事件格式如 ...

背景 上一篇我們介紹了Kafka Streams中的消息轉換操作map，今天我們給出另一個經典的轉換操作filter的用法。依然是結合一個具體的實例展開介紹。 演示功能說明 本篇演示filt ...